package com.clj.blesample.compose;

import com.clj.blesample.entity.Result;

import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.ObservableTransformer;

/**
 * Created by jiajia on 2018/9/29.
 */

public class BaseEmptyTransformer<T extends Result> implements ObservableTransformer<T, T> {
    @Override
    public ObservableSource<T> apply(Observable<T> upstream) {
        return upstream
                .compose(new EmptyTransformer<>())
                .compose(new SchedulerTransformer<>());
    }
}
